package com.sloth.service.impl;

import org.springframework.amqp.core.Message;
import org.springframework.messaging.handler.annotation.Header;

import java.util.Map;
import com.rabbitmq.client.Channel;

/**
 * @author lai
 * @time 2021/11/1 16:11
 */

/**
 * 消费者
 */

public class MsgListener {

    //@RabbitListener(queues = RabbitMQConfig.deadQueueMyOrder)
    public void process(String myOrderId, Message message, @Header Map<String,Object> headers,Channel channel){



        // 判断订单是否失效
        System.out.println("订单是否失效，做的事死信队列处理流程");

        System.out.println("死信执行结束");

    }

}